package com.tc.vms.producer;

import com.tc.vms.MessageWrap;
import com.tc.vms.utils.ServiceThread;

import java.util.concurrent.LinkedBlockingQueue;

/**
 * Created by yonghua.zhang on 2015/12/21.
 */
public class RmqAsyncSendService extends ServiceThread {

    public final LinkedBlockingQueue<MessageWrap> queue;

    public RmqAsyncSendService(LinkedBlockingQueue<MessageWrap> queue) {
        this.queue = queue;
    }

    @Override
    public String getServiceName() {
        return this.getClass().getName();
    }

    @Override
    public void run() {

    }

    private void processEvents() {

    }

    private void tryToHandle() {

    }
}
